﻿using System;
using System.Collections.Generic;

namespace Zhaoxi.KafkaClient
{
	class Program
	{
		static void Main(string[] args)
		{
			//NetKafka.Pull();
			Console.WriteLine("Hello World!");
			string brokerList = "47.95.2.2:9092,39.96.34.52:9092,39.96.82.51:9093";//,39.96.82.51:9093
																				   //string brokerList = "localhost:9092";
			var topics = new List<string> { "test" };
			Console.WriteLine("请输入组名称");
			string groupname = Console.ReadLine();
			ConfulentKafka.Consumer(brokerList, topics, groupname);
		}
	}
}
